package to_hbase

import (
	"database/sql"
	"EasyData/global"
	"EasyData/hbase"
	"EasyData/sqls"
)

type TaskToHbaseOnly struct{

}
/**
	只向Hbase迁移数据，不删除源数据
 */
func (excustor TaskToHbaseOnly) TaskExcuse(item map[string]interface{}, c chan int,db *sql.DB,task *global.Task) {

	err := hbase.NewRowsInToHbase(item,task)
	if err == nil {
		sqls.UpdateRow(item,db,task)
	}
	taskDone(c)
}
